package cn.glc.daily.life.web.message.consumer.redis;

import cn.simon.free.redis.mq.annotations.RedisMessageConsumer;
import cn.simon.free.redis.mq.core.consumer.DelayRedisMessageConsumer;
import cn.simon.free.redis.mq.enums.ConsumerType;
import cn.simon.free.redis.mq.model.Message;
import lombok.extern.slf4j.Slf4j;

/**
 * @author simon
 * @date 2021/7/8 16:59
 * @copyright:
 * @modifier
 * @motto a no talent, people who have to study hard
 */
@Slf4j
@RedisMessageConsumer(queueName = "user_task_delay_queue", consumerType = ConsumerType.CLUSTER, corePoolSize = 4)
public class TaskPushRedisMessageConsumer extends DelayRedisMessageConsumer<String> {

    @Override
    protected boolean process(String s, Message message) {
        log.info("队列测试:{}", s);
        return true;
    }
}
